package com.hzncc.flowable_diboot.rabbitmq.service;

/**
 * 消息队列接口
 *
 * @author 陈广煜
 * @date 2024/5/20
 */
public interface MessageQueueService {

    void sendMessage(String message);

    void sendMessage(String topic,String message);

    void sendRetainedMessage(String topic,String message);

    /**
     * 发送延时消息
     *
     * @param exchange 延时交换机
     * @param key 路由键
     * @param message 消息
     * @param timeout 延时时间
     * @author 陈广煜
     * @date 2024/6/17
     */
    void sendDelayedMessageDirect(String exchange,String key,Object message,int timeout);
}
